package pos.data;

import java.sql.*;
import pos.domain.*;

public class JDBCViajeDAO implements IViajeDAO{

	Connection conn = ConnectionManager.getInstance().getConn();
	
	@SuppressWarnings("deprecation")
	@Override
	public void insert(Viaje viaje) {
		
		String sql = "INSERT INTO viaje (idRuta, fechaViaje, horaInicio,horaFin,idEstacionOrigen,idEstacionDestino) VALUES (?,?,?,?,?,?) ";
		PreparedStatement stmt = null;

		try {
			stmt = conn.prepareStatement(sql);
			stmt.setInt(1, viaje.getRuta().getIdRuta());
			Date fecha = new Date(viaje.getFecha().getYear(), viaje.getFecha().getMonth(), viaje.getFecha().getDay());
			stmt.setDate(2, fecha);
			stmt.setString(3,viaje.getHoraSalida().toString());
			stmt.setString(4,viaje.getHoraLlegada().toString());
			stmt.setInt(5, viaje.getEstacionOrigen().getIdEstacion());
			stmt.setInt(6, viaje.getEstacionDestino().getIdEstacion());
			
			stmt.executeUpdate();

		} catch (SQLException e) {
			System.out.println("Message: " + e.getMessage());
			System.out.println("SQLState: " + e.getSQLState());
			System.out.println("ErrorCode: " + e.getErrorCode());
		} finally {
			try {
				if (stmt != null) {
					stmt.close();
				}
			} catch (SQLException e) {
			}
		}
	}
}
